

package com.hazelcast.jet.impl.connector;

import javax.annotation.Nullable;

/**
 * Implemented by {@link com.hazelcast.jet.core.ProcessorMetaSupplier}s to indicate that they are related to a Source/Sink.
 * That is, they are a connector. {@link com.hazelcast.jet.impl.execution.init.ExecutionPlanBuilder} will handle these PMS
 * and will collect phone home data for connectors.
 */
public interface ConnectorNameAware {
    /**
     * The connector name in the phone home data. that'll be used in the phone homes.
     * See {@link com.hazelcast.jet.pipeline.ConnectorNames}
     */
    @Nullable
    String getConnectorName();
}
